package org.apache.rocketmq.store;

import java.util.Map;

/**
 * @课程描述:从零带你写框架系列中的课程，整个系列包含netty，xxl-job，rocketmq，nacos，sofajraft，spring，springboot，disruptor，编译器，虚拟机等等。
 * @author：陈清风扬，个人微信号：chenqingfengyangjj。
 * @date:2025/6/25
 * @方法描述：消息到达监听器接口
 */
public interface MessageArrivingListener {


    void arriving(String topic, int queueId, long logicOffset, long tagsCode,
                  long msgStoreTime, byte[] filterBitMap, Map<String, String> properties);
}
